package com.example.mq.mqserver.core;

import lombok.Data;

/**
 * 表示一个消费者
 */
@Data
public class Consumer {
    private String consumerTag;//  消费者标识
    private String queueName;//  消费者订阅的队列
    private boolean autoAck;//  是否自动应答
    private Consume consume;//  消费回调

    public Consumer(String consumerTag, String queueName, boolean autoAck, Consume consume) {
        this.consumerTag = consumerTag;
        this.queueName = queueName;
        this.autoAck = autoAck;
        this.consume = consume;
    }
}
